package com.weic.spark.scala.p3.shared

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @Auther:BigData-weic
 * @ClassName:_03AccumulatorOps
 * @Date:2020/12/9 0:12
 * @功能描述: $FunctionDescription
 * @Version:1.0
 */
object _03AccumulatorOps {
	def main(args: Array[String]): Unit = {
		val conf = new SparkConf()
			.setAppName("_02AccumulatorOps")
			.setMaster("local[*]")
		val sc = new SparkContext(conf)
		val listRDD = sc.parallelize(
			List(
				"a second spark a spark is shared second",
				"spark shared be shared in second spark"
			)
		)
		/**
		 *
		 */

		sc.stop()
	}

}
